package com.haozhen.streamsink;

import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.redis.RedisSink;

/**
 * @author haozhen
 * @email haozh@ync1.com
 * @date 2021/2/26  0:00
 */
public class MySink {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStreamSource<String> data1 = env.fromElements("hello");



//        data1.addSink();

        env.execute();
    }
}
